
package com.lry.message;

import lombok.Data;

@Data
public class MessageExt extends Message {
    private static final long serialVersionUID = 5720810158625748049L;

    private String brokerName;
    private int queueId;
    private int storeSize;
    private long queueOffset;
    private long storeTimestamp;
    private String msgId;
    private long commitLogOffset;
    private int bodyCRC;
    private int reconsumeTimes;

    public MessageExt() {
    }

    public MessageExt(int queueId,  long storeTimestamp, String msgId) {
        this.queueId = queueId;
        this.storeTimestamp = storeTimestamp;
        this.msgId = msgId;
    }


}
